# -*- coding: utf-8 -*-
from datetime import timedelta
from utils.operators.external_dag_sensor import ExternalDagSensor
from airflow.operators.dummy_operator import DummyOperator

jms_dws__dws_wide_unsign_whole_effect_dt = ExternalDagSensor(
    task_id='jms_dws__dws_wide_unsign_whole_effect_dt',
    external_dag_id='jms_core_wide_day',
    external_task_id='jms_dws__dws_wide_unsign_whole_effect_dt',
    external_execution_date_time='{{ execution_date | cst_ds }} 03:30:00',
    execution_delta_time_unit='days',
    execution_delta=0,
    allowed_states='success',
    mode='reschedule',
    timeout=600
)